package org.example.util;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

//@Component
public class KafkaConsumer {

    @KafkaListener(topics = "test-ken-io", groupId = "logs_appss")
    public void receiveMessage(String message) {
        System.out.println("Received message: " + message);
    }
}
